package org.example.device.kafka.produce;

import org.example.base.kafka.KafkaMsgSendProducerBase;
import org.example.device.kafka.event.DeviceNotifyKafkaEvent;
import org.springframework.stereotype.Component;

@Component
public class DeviceSendProducerImpl extends KafkaMsgSendProducerBase<String, DeviceNotifyKafkaEvent> implements DeviceKafkaProducer {
    @Override
    public void deviceNotify(String topic, DeviceNotifyKafkaEvent deviceNotifyKafkaEvent) {
        this.sendMsg(topic, deviceNotifyKafkaEvent);
    }
}
